//package com.rongji.cms.tools.websocket.handler; /**
// * @author yang
// * @date 2023/2/6 9:48
// * @description
// */
//
//import com.corundumstudio.socketio.SocketIOClient;
//import com.corundumstudio.socketio.SocketIOServer;
//import com.corundumstudio.socketio.annotation.OnConnect;
//import com.corundumstudio.socketio.annotation.OnDisconnect;
//import com.rongji.cms.tools.websocket.util.SocketUtil;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import javax.annotation.PostConstruct;
//import javax.annotation.PreDestroy;
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.stereotype.Component;
//
//
///**
// * @author yang
// * @create 2023/2/6
//**/
//@Component
//@Slf4j
//public class SocketIoHandler {
//
//    @Autowired
//    private SocketIOServer socketIoServer;
//
//
//    @PreDestroy
//    private void destroy(){
//        try {
//            socketIoServer.stop();
//        }catch (Exception e){
//            e.printStackTrace();
//        }
//    }
//    @OnConnect
//    public void connect(SocketIOClient client) {
//        String userFlag = client.getHandshakeData().getSingleUrlParam("userFlag");
//        SocketUtil.connectMap.put(userFlag, client);
//        log.info("客户端userFlag: "+ userFlag+ "已连接");
//    }
//    @OnDisconnect
//    public void onDisconnect(SocketIOClient client) {
//        String userFlag = client.getHandshakeData().getSingleUrlParam("userFlag");
//        log.info("客户端userFlag:" + userFlag + "断开连接");
//        SocketUtil.connectMap.remove(userFlag, client);
//    }
//
//}
